package customerEnter.Frame.Utils;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Iterator;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;

import customerEnter.Frame.DaoDataTransmission.WebAppsInfo;
import customerEnter.tool.WhetherToEmpty;

/**
 * 文件上傳的工具包 是基於請求的
 * 
 * 类名称：FileUploadUtil 类描述： 创建人：dy 创建时间：2016-5-13 上午9:21:44
 * 
 */
public class FileUploadUtil {

	private static String				savePath;
	private static DiskFileItemFactory	factory	= new DiskFileItemFactory();
	private static ServletFileUpload	upload	= new ServletFileUpload(factory);

	public static void systemUploadUrl() {
		savePath = WebAppsInfo.webUrl;
		// 分為linux路徑和windows 路徑
		String winds = "UploadFile\\" + DateUtils.getYear() + "\\" + DateUtils.getMoth() + "\\" + DateUtils.getDay();
		String Linux = "UploadFile/" + DateUtils.getYear() + "/" + DateUtils.getMoth() + "/" + DateUtils.getDay();
		savePath += WebAppsInfo.System.contains("Windows") ? winds : Linux;
	}

	/**
	 * 圖片上傳
	 */
	@SuppressWarnings("rawtypes")
	public static String uploadImg(HttpServletRequest request, HttpServletResponse response) throws Exception {
		// 判斷路徑是什麼
		systemUploadUrl();
		// 判斷路徑存不存在
		FileImagesPath();
		// 獲取文件解析工廠
		GetFactory();
		List items = upload.parseRequest(request);
		Iterator itr = items.iterator();
		String filePath = "";
		try {
			// 循環上傳圖片
			filePath = WhileImageUpload(itr);
		} catch (Exception e) {
			System.out.println("上传文件失败！");
		}
		return filePath;
	}

	private static void FileImagesPath() {
		File filee = new File(savePath);
		if (!filee.exists() && !filee.isDirectory()) {
			System.out.println(savePath + "文件上傳目录不存在，需要創建");
			// 创建目录
			try {
				filee.setWritable(false, true);
				filee.mkdirs();
				System.out.println(savePath + "創建成功");
			} catch (Exception e) {
				System.out.print(savePath + "創建失敗   請手動創建  ");
				Log4j.Log4JOutError(e.getMessage());
			}

		}
	}

	private static void GetFactory() {
		if (WhetherToEmpty.ObjectWhetherToEmpty(factory)) {
			factory = new DiskFileItemFactory();
			upload = new ServletFileUpload(factory);
		}
	}

	@SuppressWarnings({ "rawtypes" })
	private static String WhileImageUpload(Iterator itr) throws Exception {
		String filePath = "";
		while (itr.hasNext()) {
			FileItem item = (FileItem) itr.next();
			if (!item.isFormField()) {
				if (item.getName() != null && !item.getName().equals("")) {
					File tempFile = new File(item.getName());

					File file = new File(savePath, System.currentTimeMillis() + tempFile.getName());

					try {
						item.write(file);
						// 保存上傳的文件的地址路徑
						// ReleaseResultDao.saveUpdateFile(file.getPath());
						filePath += file.getPath() + ",";
					} catch (Exception e) {
						System.out.println(item.getName() + "上傳失敗");
					}
				} else {
					System.out.println("沒有選擇上傳文件");
				}
			}
		}
		return filePath;
	}

	/**
	 * 文件上傳
	 */
	@SuppressWarnings("unused")
	public static void upload(HttpServletRequest request, HttpServletResponse response) throws ServletException,
			IOException {
		FileImagesPath();
		// 消息提示

		String message = "";
		try {
			// 使用Apache文件上传组件处理文件上传步骤：
			// 1、创建一个DiskFileItemFactory工厂
			DiskFileItemFactory factory = new DiskFileItemFactory();
			// 2、创建一个文件上传解析器
			ServletFileUpload upload = new ServletFileUpload(factory);
			// 解决上传文件名的中文乱码
			upload.setHeaderEncoding("UTF-8");
			// 3、判断提交上来的数据是否是上传表单的数据
			if (!ServletFileUpload.isMultipartContent(request)) {
				// 按照传统方式获取数据
				return;
			}
			// 4、使用ServletFileUpload解析器解析上传数据，解析结果返回的是一个List<FileItem>集合，每一个FileItem对应一个Form表单的输入项
			List<FileItem> list = upload.parseRequest(request);
			for (FileItem item : list) {
				// 如果fileitem中封装的是普通输入项的数据
				if (item.isFormField()) {
					String name = item.getFieldName();
					// 解决普通输入项的数据的中文乱码问题
					String value = item.getString("UTF-8");
					// value = new String(value.getBytes("iso8859-1"),"UTF-8");
					System.out.println(name + "=" + value);
				} else {// 如果fileitem中封装的是上传文件
						// 得到上传的文件名称，
					String filename = item.getName();
					System.out.println(filename);
					if (filename == null || filename.trim().equals("")) {
						continue;
					}
					// 注意：不同的浏览器提交的文件名是不一样的，有些浏览器提交上来的文件名是带有路径的，如：
					// c:\a\b\1.txt，而有些只是单纯的文件名，如：1.txt
					// 处理获取到的上传文件的文件名的路径部分，只保留文件名部分
					filename = filename.substring(filename.lastIndexOf("\\") + 1);
					// 获取item中的上传文件的输入流
					InputStream in = item.getInputStream();
					// 创建一个文件输出流
					FileOutputStream out = new FileOutputStream(savePath + "\\" + filename);
					// 创建一个缓冲区
					// 判断输入流中的数据是否已经读完的标识
					int len = 0;
					// 循环将输入流读入到缓冲区当中，(len=in.read(buffer))>0就表示in里面还有数据
					while ((len = in.read(new byte[1024])) > 0) {
						out.write(new byte[1024], 0, len);
					}
					// 关闭输入流
					in.close();
					// 关闭输出流
					out.close();
					// 删除处理文件上传时生成的临时文件
					item.delete();
					message = "文件上传成功！";
				}
			}
		} catch (Exception e) {
			message = "文件上传失败！";
			e.printStackTrace();
		}
	}
}
